google.golang.org/grpc.serverStream.s (field)
20 uses
google.golang.org/grpc (current package)
server.go#L1607: s: stream,
server.go#L1692: ss.s.WriteStatus(st)
server.go#L1754: Trailer: ss.s.Trailer(),
server.go#L1761: ss.s.WriteStatus(appStatus)
server.go#L1772: Trailer: ss.s.Trailer(),
server.go#L1779: return ss.s.WriteStatus(statusOK)
stream.go#L1634: s *transport.ServerStream
stream.go#L1678: return ss.s.SetHeader(md)
stream.go#L1687: err = ss.s.SendHeader(md)
stream.go#L1689: h, _ := ss.s.Header()
stream.go#L1708: ss.s.SetTrailer(md)
stream.go#L1727: ss.s.WriteStatus(st)
stream.go#L1739: if sendCompressorsName := ss.s.SendCompress(); sendCompressorsName != ss.sendCompressorName {
stream.go#L1766: if err := ss.s.Write(hdr, payload, &transport.WriteOptions{Last: false}); err != nil {
stream.go#L1772: h, _ := ss.s.Header()
stream.go#L1789: ss.statsHandler.HandleRPC(ss.s.Context(), outPayload(false, m, dataLen, payloadLen, time.Now()))
stream.go#L1810: ss.s.WriteStatus(st)
stream.go#L1824: if err := recv(&ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, payInfo, ss.decompressorV1, true); err != nil {
stream.go#L1845: ss.statsHandler.HandleRPC(ss.s.Context(), &stats.InPayload{
stream.go#L1868: if err := recv(&ss.p, ss.codec, ss.s, ss.decompressorV0, m, ss.maxReceiveMessageSize, nil, ss.decompressorV1, true); err == io.EOF {